﻿using Developer.Core.FrameWork.GlobalVar;
using Developer.Core.FrameWork.RedisExtensions.RedisSubscribeInit.Abstractions;
using Developer.Core.FrameWork.RedisExtensions.RedisSubscribeInit.Attributes;
using System;
using System.Threading.Tasks;

namespace Developer.Core.FrameWork.RedisExtensions.RedisSubscribeHandling
{
    public class RedisSubscribe : IRedisSubscribe
    {
        [Subscribe(GlobalVars.RedisKey)]
        private async Task SubRedisLoging(string msg)
        {
            Console.WriteLine($"订阅者 1 从 队列{GlobalVars.RedisKey} 消费到/接受到 消息:{msg}");

            await Task.CompletedTask;
        }
    }
}
